6fbe140959e2117c77ebcf45cff503678881467e,interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java,AbstractInteropTest,emptyStream,#,372
Before Change
@Test(timeout = 10000)
public void emptyStream() throws Exception {
@SuppressWarnings("unchecked")
StreamObserver<StreamingOutputCallResponse> responseObserver = mock(StreamObserver.class);
StreamObserver<StreamingOutputCallRequest> requestObserver
= asyncStub.fullDuplexCall(responseObserver);
requestObserver.onCompleted();
verify(responseObserver, timeout(operationTimeoutMillis())).onCompleted();
verifyNoMoreInteractions(responseObserver);
}
@Test(timeout = 10000)
After Change
@Test(timeout = 10000)
public void emptyStream() throws Exception {
StreamRecorder<StreamingOutputCallResponse> responseObserver = StreamRecorder.create();
StreamObserver<StreamingOutputCallRequest> requestObserver
= asyncStub.fullDuplexCall(responseObserver);
requestObserver.onCompleted();
responseObserver.awaitCompletion(operationTimeoutMillis(), TimeUnit.MILLISECONDS);
}
@Test(timeout = 10000)